package cn.lecosa.spark.java

import org.apache.spark.SparkConf
import org.apache.spark.SparkContext


object ScalaObjectDemo extends  App {

  
      //创建配置对象
    val conf = new SparkConf();
    //设定应用名称
    conf.setAppName("SparkDemo2")
    //设定mater地址
    conf.setMaster("local[2]"); //此时，程序在本地运行，不需要安装spark集群
    //基于conf创建出sc对象
    val sc = new SparkContext(conf);

    
//    println("hello zhaojun i miss you very much");
//    say3();
    
    
    		System.setProperty("es.set.netty.runtime.available.processors", "false");
//    		  var idCard=   ty.getIdcard("13807779980");
//		  println(idCard);

    def say(arr:Array[String]){
     val rdd = sc.parallelize(arr)
     println(rdd.collect().mkString("---"));
     
    }

    /**
      * 先去调用java方法
      * @return
      */
    def say3(): Int ={
        var tmp=JavaDemo.say2("4");
        tmp
    }
}